package com.kob.backend.service.impl.user.chat;

import com.kob.backend.mapper.ChatMapper;
import com.kob.backend.pojo.Message;

import com.kob.backend.service.user.chat.ChatMessageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
public class ChatMessageServiceImpl implements ChatMessageService {

    @Autowired
    private ChatMapper chatMapper;

    @Override
    public List<Message> getMessages() {
        // 编写查询留言列表的业务逻辑，可以直接调用chatMapper或其他数据访问层方法来获取数据
        // 示例代码：
        return chatMapper.selectList(null);
    }

    @Override
    @Transactional
    public Map<String, String> postMessage(Message message) {
        Map<String, String> result = new HashMap<>();
        try {
            // 编写发布留言的业务逻辑，可以使用chatMapper或其他数据访问层方法来插入留言数据
            // 示例代码：
            chatMapper.insert(message);

            result.put("status", "success");
            result.put("message", "留言发布成功");
        } catch (Exception e) {
            // 处理异常，例如数据库操作失败
            e.printStackTrace();
            result.put("status", "failed");
            result.put("message", "留言发布失败");
        }
        return result;
    }
}
